package com.sdp.irrigation.kafka.consumer;

import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory;
import org.springframework.kafka.config.KafkaListenerEndpointRegistry;

public class KafkaConsumerManager {

	@SuppressWarnings("rawtypes")
	private ConcurrentKafkaListenerContainerFactory factory;
	
	private KafkaListenerEndpointRegistry register;
	
	@SuppressWarnings("rawtypes")
	public KafkaConsumerManager(ConcurrentKafkaListenerContainerFactory factory, KafkaListenerEndpointRegistry register)
	{
		this.factory = factory;
		this.register = register;
	}
	
	public KafkaListenerEndpointRegistry getRegister()
	{
		return this.register;
	}
	
	@SuppressWarnings("rawtypes")
	public ConcurrentKafkaListenerContainerFactory getListenerContainerFactory()
	{
		return this.factory;
	}
}
